package com.caption.mq.config;
import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;

/**
 * @description: rocketMQ公共配置
 * @author: 码农
 * @date: 2022-01-14 22:54:49
 */
@ConfigurationProperties(prefix = "spring.rocketmq")
@Data
public class MqProperties {
    /**
     *服务端地址
     */
    private String nameServer;

    private String productGroup;

    private Integer sendMsgTimeout;

    /**
     * 消费线程池最大线程数 配置为空的不设置值
     */
    private Integer consumeThreadMax;
    /**
     * 消费组group生成最小线程数
     */
    private Integer consumeThreadMin;
    /**
     * 批量拉取数据，一次从broker拉取消息条数
     */
    private Integer pullBatchSize;
    /**
     * 消费端批量消费每次处理消息条数
     */
    private Integer consumeMessageBatchMaxSize;
}
